import pandas as pd
import pymysql
from sqlalchemy import create_engine
#创建数据框
product={'分类':["居家","居家","娱乐","娱乐","科技","科技"],
         "商店":['家乐福','大润发','家乐福','全联超','大润发','家乐福'],
         "价格":[11.42,23.50,19.99,15.95,55.75,111.25]}
#转为数据框
df=pd.DataFrame(product,columns=['分类','商店','价格'])
#保存数据

# df.to_csv("product.csv",index=False,encoding='utf_8_sig')
# #记得要加上后面的，不然编码不对
# df.to_json('product.json',force_ascii=False)

#读取功能
mql=pd.read_csv('product.csv',encoding='utf-8')
mql1=pd.read_json('product.json')

#建立数据引擎
db=create_engine('mysql+pymysql://root:123456@localhost:3306/mql?charset=utf8')
df.to_sql("product",db,if_exists="replace")

